package net.skystudio.es.test;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class KafkaConsumer {

    //    @KafkaListener(id = OPERATE_LOG_TOPIC, topics = OPERATE_LOG_TOPIC)
    public void listenOperateLog(String msgData) {
        log.info("demo receive : " + msgData);
    }

    //    @KafkaListener(id = SYSTEM_LOG_TOPIC, topics = SYSTEM_LOG_TOPIC)
    public void listenSystemLog(String msgData) {
        log.info("demo receive : " + msgData);
    }

}
